package com.newbee;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;

/**
 * Created by iss on 17/7/18.
 */
public class QueueListenter1 implements MessageListener {

    public void onMessage(Message message) {
        System.out.println(message);
        System.out.println(new String(message.getBody()));
    }
}
